#ifndef __APP_MQTT_H
#define __APP_MQTT_H

#include "MQTTClient.h"
#include "app_common.h"
#include "log/log.h"

typedef void (*mqtt_callback)(MQTTClient_message *message);

returnType_t app_mqtt_init(void);

returnType_t app_mqtt_close(void);

returnType_t app_mqtt_publish(char *payload, int payloadlen);

returnType_t app_mqtt_regRecvCb(mqtt_callback cb);

#endif